package com.test.study.ToolsUtils.strom.trident;

import org.apache.storm.trident.operation.BaseFunction;
import org.apache.storm.trident.operation.TridentCollector;
import org.apache.storm.trident.tuple.TridentTuple;

public class MyTridentFunction extends BaseFunction {
	private static final long serialVersionUID = 8186482217847292118L;

	@Override
	public void execute(TridentTuple tuple, TridentCollector collector) {
	//从tuple中获取数据
		Integer integer = tuple.getInteger(0);
		System.out.println(integer);
		
	}

}
